/**     
 * @Title: DemoSubscriber.java   
 * @Package me.xxy.mq.client   
 * @Description: TODO
 * @author weiwei 
 * @date 2018年6月1日 下午5:16:38   
 * @version V1.0     
 */
package me.xxy.mq.client;

import me.xxy.mq.AbstractSubscriber;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

/**
 * @ClassName: DemoSubscriber
 * @Description: TODO
 * @author weiwei
 * @date 2018年6月1日 下午5:16:38
 * 
 */
@Service
public class DemoSubscriber extends AbstractSubscriber {

	private static final Logger LOG = LoggerFactory.getLogger(DemoSubscriber.class);

	public final static String DEFAULT_CHANNELS = "DEFAULT_CHANNELS";

	public DemoSubscriber() {
		super(DEFAULT_CHANNELS);
	}

	public DemoSubscriber(String... channels) {
		super(channels);
	}

	@Override
	public void onMessage(String channel, String message) {
		LOG.info("DemoSubscriber :: channel >> {}, message >> {}", channel, message);
	}

}
